package com.ice.work.moment.facade.socket.store;

import com.corundumstudio.socketio.SocketIOClient;
import com.ice.work.moment.facade.socket.request.AckRequest;
import org.apache.http.concurrent.BasicFuture;

import java.util.UUID;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ConcurrentHashMap;

/**
 * @Description
 * @Author DELL
 * @Create 2019-06-25
 * @Since 1.0.0
 */
public interface GlobalStore  {
    /**
     * 保存websocket Client
     */
    ConcurrentHashMap<Long, SocketIOClient> WEB_SOCKET_CLIENT = new ConcurrentHashMap<>();
    /**
     * 保存websocket Client
     */
    ConcurrentHashMap<UUID,Long> SESSION_CLIENT = new ConcurrentHashMap<>();

    BlockingQueue<AckRequest> CHECK_RESPONSE = new ArrayBlockingQueue<>(1024);

    ConcurrentHashMap<Long, BasicFuture<String>> CHECK_REQUEST = new ConcurrentHashMap<>();



}
